package t20250320.Wc;

import org.apache.flink.configuration.Configuration;
import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;

import java.util.ArrayList;
import java.util.Arrays;

public class MySink extends RichSinkFunction<ArrayList<String[]>> {

    @Override
    public void open(Configuration parameters) throws Exception {

        System.out.println("open");
    }

    @Override
    public void invoke(ArrayList<String[]> value, Context context) throws Exception {

        for (String[] s : value) {
            System.out.println(Arrays.toString(s));
        }
    }
}
